5e0cdd4456a8c6a252d706bdc7cb89038df09959,runtime/src/test/java/io/rx_cache/internal/ProvidersDynamicsKeysRxCacheTest.java,ProvidersDynamicsKeysRxCacheTest,Pagination,#,53
Before Change
List<Mock> mocksPage3 = createMocks(SIZE);
String mockPage3Value = mocksPage3.get(0).getMessage();
subscriber = new TestSubscriber<>();
providersRxCache.getMocksPaginate(Observable.just(mocksPage3), new DynamicKey(3))
.subscribe(subscriber);
subscriber.awaitTerminalEvent();
subscriber = new TestSubscriber<>();
providersRxCache.getMocksPaginate(Observable.<List<Mock>>just(null), new DynamicKey(1))
.subscribe(subscriber);
subscriber.awaitTerminalEvent();
assertThat(subscriber.getOnNextEvents().get(0).get(0).getMessage(), is(mockPage1Value));
subscriber = new TestSubscriber<>();
providersRxCache.getMocksPaginate(Observable.<List<Mock>>just(null), new DynamicKey(2))
.subscribe(subscriber);
subscriber.awaitTerminalEvent();
assertThat(subscriber.getOnNextEvents().get(0).get(0).getMessage(), is(mockPage2Value));
subscriber = new TestSubscriber<>();
providersRxCache.getMocksPaginate(Observable.<List<Mock>>just(null), new DynamicKey(3))
.subscribe(subscriber);
subscriber.awaitTerminalEvent();
assertThat(subscriber.getOnNextEvents().get(0).get(0).getMessage(), is(mockPage3Value));
}
After Change
List<Mock> mocksPage3 = createMocks(SIZE);
String mockPage3Value = mocksPage3.get(0).getMessage();
testObserver =
providersRxCache.getMocksPaginate(Observable.just(mocksPage3), new DynamicKey(3)).test();
testObserver.awaitTerminalEvent();
testObserver =
providersRxCache.getMocksPaginate(ClearProvider.<List<Mock>>now(), new DynamicKey(1))
.test();
testObserver.awaitTerminalEvent();
assertThat(testObserver.values().get(0).get(0).getMessage(), is(mockPage1Value));
testObserver =
providersRxCache.getMocksPaginate(ClearProvider.<List<Mock>>now(), new DynamicKey(2))
.test();
testObserver.awaitTerminalEvent();
assertThat(testObserver.values().get(0).get(0).getMessage(), is(mockPage2Value));
testObserver =
providersRxCache.getMocksPaginate(ClearProvider.<List<Mock>>now(), new DynamicKey(3))
.test();
testObserver.awaitTerminalEvent();
assertThat(testObserver.values().get(0).get(0).getMessage(), is(mockPage3Value));
}